package rddSummary.transition.value_type

import org.apache.spark.{SparkConf, SparkContext}

object test_map {
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf().setMaster("local").setAppName("test")
    val sparkContext = new SparkContext(sparkConf)

    /**
     * 将处理的数据逐条进行映射转换，这里的转换可以是类型的转换，也可以是值的转换。
     */

    val dates = sparkContext.makeRDD(List(1, 2, 3, 4))
    val mapRDD = dates.map(x => (x, 1))
    val mapRDD1 = dates.map(x => x*2)

    mapRDD.collect().foreach(println)
    mapRDD1.collect().foreach(println)

    sparkContext.stop()
  }

}
